﻿using System;
using System.Threading;
using System.Threading.Tasks;

namespace ActiveMqConsole
{
    public class Program
    {
        static void Main(string[] args)
        {
            MqHelper.ConsumeMessageFromQueue("strong.ai.litter");

            //for (int i = 0; i < 50; i++)
            //{
            //    Console.WriteLine(i);
            //    MqHelper.ProduceMessageToQueue("CbsTestQueue", "你好");
            //}

            //Task.Run(() =>
            //{
            //    for (int i = 0; i < 50; i++)
            //    {
            //        Thread.Sleep(300);
            //        MqHelper.ProduceMessageToQueue("strong.ai.litter",
            //            JsonHelper.SerializeToJson(new {time = DateTime.Now}));
            //    }
            //});

            //Task.Run(() =>
            //{
            //    for (int i = 0; i < 50; i++)
            //    {
            //        Thread.Sleep(300);
            //        MqHelper.ProduceMessageToQueue("strong.ai.litter",
            //            JsonHelper.SerializeToJson(new { time = DateTime.Now }));
            //    }
            //});

            //Task.Run(() =>
            //{
            //    for (int i = 0; i < 50; i++)
            //    {
            //        Thread.Sleep(300);
            //        MqHelper.ProduceMessageToQueue("strong.ai.litter",
            //            JsonHelper.SerializeToJson(new { time = DateTime.Now }));
            //    }
            //});

            try
            {
                //MqHelper.ConsumeMessageFromQueue("strong.ai.litter");
            }
            catch (Exception e)
            {
                Console.WriteLine(e);
            }
            

            //Console.WriteLine("Hello World!");
            Console.ReadLine();
        }
    }
}
